package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.arithmetic.common.Cn6BasicDataInfo;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.broadcast.Broadcast;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;
import java.util.HashMap;

public interface LoadCn6BasicDataInfoService extends Serializable {
    Broadcast<HashMap<Long, Cn6BasicDataInfo>> getCn6BasicDataInfoRdd(SparkSession spark, JavaSparkContext jsc);
}
    